package com.example.review;

import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;

import java.io.IOException;

/**
 * Created with IntelliJ IDEA.
 * ClassName: ThreadHBase
 * Package: com.example.review
 * Description:
 * User: fzykd
 *
 * @Author: LQH
 * Date: 2023-08-06
 * Time: 11:30
 */

//多线程创建连接
public class ThreadHBase {

    public static Connection connection;

    //HBase是一个重量级的连接 创建一个单例的连接方式 多个线程来使用
    static {
        //在配置文件中 配置了连接zk的参数 那么就不用使用configuration配置了

        //就直接创建连接
        try {
            connection = ConnectionFactory.createConnection();
        }catch (IOException e){
            e.printStackTrace();
        }

    }

    //使用类单例模式,确保使用一个连接，可以同时用于多个线程。
    public static void main(String[] args) throws IOException {

        System.out.println(connection);

        //关闭连接
        connection.close();

    }

}
